#!/usr/bin/env python
# _*_ coding:utf-8 _*_

TOTAL_TOPIC = {
    "PM": [
        "AntiRansomwareDetection",
        "Archive_LockResponse",
        "HasLockRequest",
        "HostAgentRegisterMessage",
        "Job.stop.task",
        "MigrateHostImmediateSchedule",
        "MigrateHostIntervalSchedule",
        "MigrateHostUnexpectedEndSchedule",
        "RescanEnvironment",
        "ResourceProtectionModifySchedule",
        "ResourceProtectionSchedule",
        "Sanning_environment_v2",
        "ScanEnvironment",
        "ScanVmUnderComputeResource",
        "SlaChangedRequest",
        "SystemBackupMessage",
        "alarm_dump_topic",
        "anybackup.host.deleted",
        "archive",
        "archive.copies.to.repository",
        "cluster.delete",
        "cluster.sync",
        "copy.check.request",
        "copy.delete",
        "copy.delete.init",
        "copy.delete.job.monitor.finished",
        "copy.delete.locked",
        "copy.delete.request",
        "copy.replica.success",
        "copy.replication.completed",
        "copy.retention",
        "copy.save.event",
        "copy.save.request",
        "copyVerifyExecute",
        "delete.user",
        "environment-health-check",
        "environment-health-check-schedule",
        "host.agent.update.process",
        "import.archive.copies",
        "initialize.replication",
        "job.abort.unlocked",
        "job.complete",
        "job.force.stop",
        "job.log.update",
        "job_schedule_manual_scan_environment",
        "job_schedule_manual_scan_resource",
        "live-mount.clone-copy.clean",
        "live-mount.complete.process",
        "live-mount.copy.clone",
        "live-mount.execute.process",
        "live-mount.execute.process.without.clone.copy",
        "live-mount.execute.request",
        "live-mount.migrate.complete",
        "live-mount.migrate.request",
        "live-mount.schedule",
        "live-mount.unmount-before-execute",
        "live-mount.unmount.action",
        "live-mount.unmount.complete",
        "live-mount.unmount.request",
        "live-mount.unmounted-before-execute.fail",
        "live-mount.unmounted-before-execute.process",
        "localstorage.auth.success",
        "monitor.longtime.running.job",
        "protection.archive",
        "protection.archive.done",
        "protection.archive.success",
        "protection.backup",
        "protection.backup.completed",
        "protection.backup.done",
        "protection.backup.init",
        "protection.backup.locked",
        "protection.backup.success",
        "protection.backup.timeout.check",
        "protection.backup.unlocked",
        "protection.change.event",
        "protection.remove.event",
        "protection.replication",
        "protection.restore",
        "protection.restore.done",
        "protection.restore.done.finish",
        "protection.restore.execute.v2",
        "replication.complete",
        "replication.need.deleted",
        "resource.added",
        "resource.deleted",
        "restore",
        "restore.process",
        "schedule.archiving",
        "schedule.backup",
        "schedule.cert.client.clean",
        "schedule.job.monitor.start",
        "schedule.replication"
    ],

    "DME": [
        "ArchiveQueryS3ConnectRequest",
        "ArchiveQuerySubTaskStatusRequest",
        "ArchiveQuerySubTaskStatusResponse",
        "ArchiveScanTapeLibraryRequest",
        "DWSGetArchiveDirtyRangeRequest",
        "DWSGetArchiveDirtyRangeResponse",
        "DeleteArchiveBackupForImportReq",
        "DeleteArchiveBackupForImportRsp",
        "EndRecoverArchiveCopyFromDatabasesResponse",
        "EndRecoverArchiveCopyRequest",
        "EndRecoverArchiveCopyResponse",
        "ExportAppMetaDataFromDWSRequest",
        "ExportAppMetaDataFromDatabasesRequest",
        "ExportAppMetaDataFromVmwareRequest",
        "ExportAppMetaDataResponse",
        "GetArchiveRecoverTaskProgressFromDatabasesResponse",
        "GetArchiveRecoverTaskProgressRequest",
        "GetArchiveRecoverTaskProgressResponse",
        "GetArchiveServerInfoReq",
        "GetArchiveServerInfoRsp",
        "LockResponse",
        "OracleGetArchiveDirtyRangeRequest",
        "OracleGetArchiveDirtyRangeResponse",
        "ReplicationExportAppMetaDataFromDatabasesRequest",
        "ReplicationExportAppMetaDataFromImportCopyRequest",
        "ReplicationExportAppMetaDataFromVmwareRequest",
        "ReplicationExportAppMetaDataResponse",
        "ScanReplicationCopyRequestToImportCopy",
        "ScanReplicationCopyRequestToOracle",
        "ScanReplicationCopyRequestToVmware",
        "ScanReplicationCopyResponse",
        "ServerCertUpdateNotice",
        "StartRecoverArchiveCopyFromDatabasesResponse",
        "StartRecoverArchiveCopyRequest",
        "StartRecoverArchiveCopyResponse",
        "UnlockResponse",
        "UpdateArchiveCopyStateRequest",
        "UpdateArchiveCopyStateResponse",
        "VmwareGetArchiveDirtyRangeRequest",
        "VmwareGetArchiveDirtyRangeResponse"
    ],

    "DEE": [
        "AnonymizeLockResponse",
        "DBRestoreCreateResource",
        "DbResourceDesesitization",
        "DbResourceDesestizationCreateJob",
        "FilesRestoreRequest",
        "IndexDeleteRequest",
        "IndexDeleteResponse",
        "IndexRequest",
        "IndexResponse",
        "LockRequest",
        "ScanRequest",
        "ScanResponse",
        "TaskCompleteMessage",
        "UnlockRequest",
        "UpdateTaskProgressMessage",
        "dee.index.request",
        "dee.index.response"
    ]
}
